package cn.topkinson.rabbitmq.dead.queue.service;

import cn.topkinson.rabbitmq.dead.queue.config.RabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

/**
 * @Author huangzihao
 * @Date 2020/12/26 19:45
 */
@Service
public class MsgService {

    @RabbitListener(queues = RabbitConfig.Q_PAY_DLX)
    public void payQueueDlx(String message) {
        System.err.println("订单超时，收到死信消息：" + message);
    }


}
